package com.sfx.concurrent.demo.MyBlockingQueue;

public interface BlockingQueue<E> {

    // 添加一个元素,如果满了,则阻塞
    void offer(E e) throws InterruptedException;

    // 带有超时时间的添加元素,如果时间过了,队列还是满的,那么就会返回false,添加元素失败
    boolean offer(E e, long timeout) throws InterruptedException;

    // 从队列中取出元素
    E poll() throws InterruptedException;
}